package com.Shuang.TCP;

import java.io.DataOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;

public class Client {
    public static void main(String[] args) throws Exception {
        //1 创建一个客户端对象，找到本机的服务端ip和端口 请求连接
        Socket socket = new Socket("127.0.0.1", 8888);

        //2 用客户端对象通信管道对象得到字节输出流
        OutputStream os = socket.getOutputStream();

        //3 将低级的字节输出流包装成数据输出流 输出数据
        DataOutputStream dos = new DataOutputStream(os);

        //4 实现客户端一直发 直到输入exit推出下线
        Scanner sc = new Scanner(System.in);
        while (true){
            System.out.println(socket.getLocalPort() + "请说：");
            String rs = sc.nextLine();

            if (rs.equals("exit")){
                System.out.println(socket.getLocalPort() + "我下线了~欢迎下次再来");
                dos.close();
                socket.close();
                break;
            }

            dos.writeUTF(rs);
            dos.flush();
        }
    }
}
